package org.example.io.handler;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import lombok.extern.slf4j.Slf4j;

import java.nio.charset.Charset;

@Slf4j
public class ServerMsgHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        // 消息有的长有的短
//        ByteBuf buf = (ByteBuf) msg;
//        buf.markReaderIndex();
//        int len = buf.readInt();
//        if (len > 0) {
//            int conLen = buf.readableBytes();
//            if (conLen != len) {
//                buf.resetReaderIndex();
//            } else {
//                byte[] contents = new byte[conLen];
//                buf.readBytes(contents);
//                log.info("内容长度：{}，内容：{}", len, new String(contents));
//            }
//        } else {
//            buf.resetReaderIndex();
//        }
        ByteBuf buf = (ByteBuf) msg;
        log.info("服务端收到消息：{}", buf.toString(Charset.defaultCharset()));

    }
}
